Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[FLINK-16738] [py] Add kinesis_egress_record builder method to Python SDK #69

Merged
merged 2 commits into from
Mar 24, 2020
Merged

[FLINK-16738] [py] Add kinesis_egress_record builder method to Python SDK #69

merged 2 commits into from
Mar 24, 2020

Conversation

tzulitai
Copy link
Contributor

This PR adds a kinesis_egress_record method to the Python SDK, so that we hide the business of building a KinesisEgressRecord message from the user.
It is similar to how we added the kafka_egress_record method to the Python SDK.

@igalshilman
Copy link
Contributor

LGTM.

@tzulitai
Copy link
Contributor Author

Thanks, merging ...

@tzulitai tzulitai merged commit cdb4d95 into apache:master Mar 24, 2020
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers
No reviews
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
2 participants
@tzulitai @igalshilman